package interfaces

import "miniDW/src/datapack"

type IContext interface {
	//获取数据源名称
	GetSourcesNames() []string

	//获取数据源数据结构
	GetSourceTableStruct(name string) (*datapack.TableStruct, error)

	//获取自身的数据结构
	GetTableStruct() *datapack.TableStruct

	//设置自身的数据结构
	SetTableStruct(ts *datapack.TableStruct) error

	//发送数据
	SendRowData(row *datapack.Row) error

	//获取数据队列
	GetRowQueue(name string) *datapack.RowQueue

	Stop()
}
